package xyz.xtt.exchange.kafka;

import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.common.internals.Topic;
import org.springframework.context.annotation.Bean;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class Consumer {
//	@Bean
//	public NewTopic myTopic() {
//		return new NewTopic("test1-topic", 1, (short) 1);
//
//	}
//
//	@KafkaListener(topics = "${kafka.topic.name}", groupId = "${kafka.group.id}")
//	public void consume(String message) {
//		System.out.println("Received message: " + message);
//	}
}
